package cn.hallele.bbts.core.module.kafka.serialization;

import cn.hallele.bbts.core.common.utils.BeanUtil;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * BBTSDeSerializer
 *
 * @author anle5
 * @since 2023/12/9 星期六 0:35
 */
public class BBTSDeSerializer implements Deserializer<Object> {
    @Override
    public Object deserialize(String topic, byte[] data) {
        return BeanUtil.byte2Obj(data);
    }
}
